package he;


import io.debezium.engine.DebeziumEngine;
import io.debezium.engine.format.Json;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ApplicationContext;

import javax.swing.event.ChangeEvent;

@SpringBootApplication
public class KafkaApp {
    public static void main(String[] args)
    {
        ApplicationContext context = SpringApplication.run(KafkaApp.class, args);
        DebeziumEngine<Json> engine = context.getBean(DebeziumEngine.class);
        new Thread(engine::run).start();    }
}
